//package thread.ThreadPool;
//
//
//import java.util.concurrent.BlockingQueue;
//import java.util.concurrent.LinkedBlockingQueue;
//
//class MyThreadPool {
//    //阻塞队列
//    BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
//    //存放任务
//    public void submit(Runnable task) throws InterruptedException {
//        queue.put(task);
//    }
//    //线程池(指定核心线程数目)
//    public MyThreadPool(int val) {
//        for(int i = 0; i < val; i++) {
//            Thread thread = new Thread(new Runnable() {
//                @Override
//                public void run() {
//                    while(true) {
//                        try {
//                            Runnable task = queue.take();
//                            task.run();
//                        } catch (InterruptedException e) {
//                            e.printStackTrace();
//                        }
//                    }
//                }
//            });
//            thread.start();
//        }
//    }
//}
//
//public class thread.ThreadPool {
//    public static void main(String[] args) throws InterruptedException {
//        MyThreadPool threadPool = new MyThreadPool(3);
//        for(int i = 0; i < 1000; i++) {
//            int num = i;
//            threadPool.submit(new Runnable() {
//                @Override
//                public void run() {
//                    System.out.println("线程:" + Thread.currentThread().getName() + "正在完成任务:" + num);
//                }
//            });
//        }
//    }
//}
